﻿using Sustainalytics.ClientDW.Synchronization.SyncProductInvolvement;
using Sustainalytics.Synchronization.Interface;
using System.Collections.Concurrent;
using System.Collections.Generic;
using Xunit;

namespace Sustainalytics.ClientDW.Synchronization.SyncPITraditional.Tests
{
    public class PITraditionalSyncStepTests
    {
        private const string MongoConnectionString = "mongodb://localhost:27017/ProductInvolvementDW_A";
        private const string ClientDWConnectionString = "mongodb://localhost:27017/ClientDW_A";

        [Fact]
        public void ISyncStep_Start_Test()
        {
            var syncStep = new PITraditionalSyncStep();

            var syncContext = new SyncContext
            {
                LastSyncTime = null,
                GAConnectionStrings = new Dictionary<string, string>
                {
                    {"ProductInvolvementDW", MongoConnectionString },
                    { "ClientDW",ClientDWConnectionString}
                },
                PreviousChanges = new List<ChangedElement>(),
                Report = new ConcurrentBag<string>()
            };

            syncStep.Start(syncContext);
        }
    }
}
